package com.we.flink.accountproxyuserlabelplatform.table;

import java.sql.Timestamp;

public class TableUser {
    public static final String KFKTABLE = "fdm.uni02_user";
    public static final String QUERYSQL =
            "select id as account_user_key, "
                    + "partner_user_id as user_key, "
                    + "if(update_time is null, TIMESTAMP '1970-01-01 08:00:00.000000', update_time) as update_time "
                    + "from "
                    + KFKTABLE;

    public long account_user_key;
    public String user_key;
    public Timestamp update_time;

    public TableUser() {}

    public TableUser(long account_user_key, String user_key, Timestamp update_time) {
        this.account_user_key = account_user_key;
        this.user_key = user_key;
        this.update_time = update_time;
    }

    public long getAccount_user_key() {
        return account_user_key;
    }

    public String getUser_key() {
        return user_key;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }

    @Override
    public String toString() {
        return "TableUser{"
                + "account_user_key="
                + account_user_key
                + ", user_key='"
                + user_key
                + '\''
                + ", update_time="
                + update_time
                + '}';
    }
}
